from my_utils.shell import ParameterUtil
from my_utils.mysql import Mysql
from config import *

sh = ParameterUtil()


def get_mysql_data_management():
    pu = ParameterUtil()
    pu.cat_hdfs(HDFS_DATA_MANAGEMENT)
    MYSQL.update(**pu.parameters)
    return Mysql(**MYSQL)


def get_mysql_hive():
    pu = ParameterUtil()
    pu.cat_hdfs(HDFS_HIVE)
    META_STORE.update(**pu.parameters)
    return Mysql(**META_STORE)
